package com.shujia;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.params.ZParams;
import redis.clients.jedis.resps.Tuple;

import java.util.Set;

public class Demo09ConnPool {
    public static void main(String[] args) {
        // 使用Redis连接池，避免频繁的创建销毁连接所带来的额外的开销
        // 创建Redis连接池
        JedisPool connPool = new JedisPool("master", 6379);

        // 从连接池中获取一个连接并使用
        Jedis jedis = connPool.getResource();

        Set<Tuple> tuples = jedis.zunionWithScores(new ZParams().aggregate(ZParams.Aggregate.SUM), "jan", "feb");
        for (Tuple tuple : tuples) {
            System.out.println(tuple);
        }
        // 不会真正关闭，而是将连接放回连接池
        jedis.close();

        // 关闭连接池
        connPool.close();

    }
}
